/*
 * =====================================================================================
 *
 *       Filename:  inmServer.h
 *
 *    Description:  
 *
 *        Version:  1.0
 *        Created:  08/10/2012 04:11:07 PM
 *       Revision:  none
 *       Compiler:  gcc/g++
 *
 *         Author:  wangtengchao , wangtengchao AT gmail.com
 *   Organization:  
 *
 * =====================================================================================
 */
#ifndef INMSERVER_H
#define INMSERVER_H 
//#include "net/tcpServer.h"
#include "tcpServer.h"
const int  headerLen = sizeof(uint32_t);

class InmServer
{
	public:
        InmServer(const inm::net::InetAddr& serverAddr,int threadNum);
        void messageCallback(const inm::net::TcpConnectPtr& t,const std::string& msg,const inm::net::Timestamp& time);
        void messageCodecCallback(const inm::net::TcpConnectPtr& t,inm::net::NetBuffer* buf,const inm::net::Timestamp& time);
        void sendMessage(const inm::net::TcpConnectPtr& tcpConn,const std::string& msg);

        void run();
        void quit();
    private:
        inm::net::TcpServer tcpServer_;
};

#endif 
